
package com.lee.job; 
 
import com.alibaba.fastjson.JSON; 
import com.lee.info.CkFlowInfo; 
import org.apache.flink.api.java.functions.KeySelector; 
 
public class CkClassifyKeyByFunction implements KeySelector<CkFlowInfo, String> { 
 
    @Override
    public String getKey(CkFlowInfo ckFlowInfo) throws Exception {
        return JSON.toJSONString(ckFlowInfo.getCkList());
    }
} 
 
 
